package cn.iocoder.yudao.framework.mq.redis.core.stream;

import org.springframework.data.redis.connection.stream.ObjectRecord;
import org.springframework.data.redis.stream.StreamListener;

/**
 * @author 梁富贵
 * @Date 2024/11/14
 **/
public class AbstractCommonRedisStreamMessageListener<T extends AbstractRedisStreamMessage>
implements StreamListener<String, ObjectRecord<String, String>> {

    public Class<T> messageClass;

    @Override
    public void onMessage(ObjectRecord<String, String> message) {
    }
}
